package com.light.dp.spark.kryo;

import com.esotericsoftware.kryo.Kryo;
import com.light.dp.spark.kryo.dto.CustomDTO;
import com.light.dp.spark.kryo.dto.DHouseholdData;
import org.apache.spark.serializer.KryoRegistrator;

/**
 * @author sjf0115
 * @Date Created in 下午2:17 18-6-29
 */
public class CustomKryoRegistrator implements KryoRegistrator {
    @Override
    public void registerClasses(Kryo kryo) {
        kryo.register(CustomDTO.class);
        kryo.register(DHouseholdData.class);
    }
}